package com.example.platformhimybodymanage.config.rabbitmq;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 队列配置时
 * @author Dhjie
 *
 */
@Configuration
public class QueueConfig {
	
	@Bean
	public Queue dirctQueuePay() {
		return new Queue(RabbitMQConfig.DIRCT_QUEUE_PAY, true, false, false);
	}

	@Bean
	public Queue dirctQueueShou() {
		return new Queue(RabbitMQConfig.DIRCT_QUEUE_SHOU, true, false, false);
	}
	
	
	
	@Bean
	public Queue fanoutQueueBeiJing() {
		return new Queue(RabbitMQConfig.FANOUT_QUEUE_BEIJING, true, false, false);
	}

	@Bean
	public Queue fanoutQueueTianJin() {
		return new Queue(RabbitMQConfig.FANOUT_QUEUE_TIANJIN, true, false, false);
	}
	
}
